package com.ls.mq.listener.impl;

import org.apache.log4j.Logger;

import com.ls.mq.iterface.MessageListener;

public class DefaultPubSubMessageListener implements MessageListener {
	Logger logger = Logger.getLogger(DefaultPubSubMessageListener.class);

	@Override
	public void doMessage(String channel, String msg) {
		logger.info(String.format("来自pubsub channel：%s 的消息是: %s", channel,msg));
	}

}
